package top.aigoo.project01.config.redis;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import redis.clients.jedis.JedisPoolConfig;
import top.aigoo.project01.cache.JedisPoolWriper;
import top.aigoo.project01.cache.JedisUtil;

/**
 * spring-redis.xml里面的配置
 * 
 * @author admin
 *
 */
@Configuration
public class RedisConfiguration {
	@Value("${redis.hostname}")
	private String hostname;

	@Value("${redis.port}")
	private int port;

	@Value("${redis.password}")
	private String password;

	@Value("${redis.pool.maxActive}")
	private int maxTotal;

	@Value("${redis.pool.maxIdle}")
	private int maxIdle;

	@Value("${redis.pool.maxWait}")
	private long maxWaitMillis;

	@Value("${redis.pool.testOnBorrow}")
	private boolean testOnBorrow;

	@Autowired
	private JedisPoolConfig jedisPoolConfig;
	@Autowired
	private JedisPoolWriper jedisWritePool;
	@Autowired
	private JedisUtil jedisUtil;

	/**
	 * 创建redis连接池的设置
	 */
	@Bean(name = "jedisPoolConfig")
	public JedisPoolConfig createJedisPoolConfig() {
		JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
//		控制一个Pool可以分配多少个jedis实例
		jedisPoolConfig.setMaxTotal(maxTotal);
		// 连接池最多可空闲maxIdle个连接，这里取值为20
		// 表示即使没有数据库连接时依然可以保持20个空闲的连接，而不被清除，随时处于待命状态
		jedisPoolConfig.setMaxIdle(maxIdle);
		// 最大等待时间，当没有可用连接时，连接池等待连接被归还的最大时间(以毫秒技术)超过时间则抛出异常
		jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
		// 在获取连接的时候回检查有效性
		jedisPoolConfig.setTestOnBorrow(testOnBorrow);

		return jedisPoolConfig;
	}

	/**
	 * 创建redis连接池，并做相应配置
	 */

	@Bean(name = "jedisWritePool")
	public JedisPoolWriper createJedisPoolWriper() {
		JedisPoolWriper jedisPoolWriper = new JedisPoolWriper(jedisPoolConfig, hostname, port, password, 1000);
		return jedisPoolWriper;
	}

	/**
	 * 创建redis工具类jedisUtil，封装好redis的连接以进行相关的操作
	 */
	@Bean(name = "jedisUtil")
	public JedisUtil createJedisUtil() {
		JedisUtil jedisUtil = new JedisUtil();
		jedisUtil.setJedisPool(jedisWritePool);
		return jedisUtil;
	}

	/**
	 * Redis的key操作
	 */
	@Bean(name = "jedisKeys")
	public JedisUtil.Keys createJedisKeys() {
		JedisUtil.Keys jedisKeys = jedisUtil.new Keys(jedisUtil);
		return jedisKeys;
	}

	/**
	 * Redis的Strings操作
	 */
	@Bean(name = "jedisStrings")
	public JedisUtil.Strings createJedisStrings() {
		JedisUtil.Strings jedisStrings = jedisUtil.new Strings(jedisUtil);
		return jedisStrings;
	}

}
